#ifndef __TASK_QUEUE__
#define __TASK_QUEUE__
#include "head.h"
#include "protocol.h"
typedef struct node_s {
    int netfd;
	// int command;
    // char *token;
    protocol_header_t header;
	char *data;
    struct node_s * pNext;
    filePath_t file_path;
} node_t;
typedef struct taskQueue_s {
    node_t *pFront;
    node_t *pRear;
    int queueSize;
} taskQueue_t;
int taskQueueInit(taskQueue_t *pqueue);
int enQueue(taskQueue_t *pqueue, int netfd,protocol_header_t *header,char *buf,filePath_t file_path);
int deQueue(taskQueue_t *pqueue);
int printQueue(taskQueue_t *pqueue);
#endif

// typedef struct protocol_header_s
// {
//     int magic;                   // 魔数
//     int data_length;             // 后续数据长度
//     CommandType_e command;       // 客户端发送的为命令类型
//     ResponseResults_e resp_type; // 服务端处理结果
//                                  // int request_id;  // 请求ID
//     char token[JWT_TOKEN_LENGTH]; // 新增JWT Token字段
// } protocol_header_t;